//package com.learn.order.message;
//
//import org.springframework.cloud.stream.annotation.EnableBinding;
//import org.springframework.cloud.stream.annotation.StreamListener;
//import org.springframework.messaging.handler.annotation.SendTo;
//import org.springframework.stereotype.Component;
//
//import lombok.extern.slf4j.Slf4j;
//
//@Component
//@EnableBinding(StreamClient.class)
//@Slf4j
//public @SuppressWarnings("deprecation") class StreamReceiver {
//
//	@StreamListener(value = StreamClient.INPUT)
//	@SendTo(StreamClient.INPUT_NOTFIY)
//	public String proess(Object message) {
//		String msg = (String) message;
//		System.err.println(msg);
//		log.info("Stream input接收到的消息:{},{}", message, msg);
//		return "ok";
//	}
//
//	@StreamListener(value = StreamClient.INPUT_NOTFIY)
//	public void proess2(Object message) {
//		String msg = (String) message;
//		System.err.println(msg);
//		log.info("Stream input_notify接收到的消息:{},{}", message, msg);
//	}
//
//}
